package com.ahcloud.edas.common.kafka;

import java.util.Properties;

/**
 * @program: edas-common
 * @description:
 * @author: YuKai Fan
 * @create: 2024/4/20 10:38
 **/
public interface KafkaConsumerInner {

    /**
     * 获取消费者属性
     * @return
     */
    Properties getProperties();

    /**
     * 拉取消息
     */
    void pullMessage();

    /**
     * 消费者启动
     */
    void consumerStart();

    /**
     * 消费者关闭
     */
    void consumerShutdown();
}
